package wx;

import java.util.Date;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

/**
 * 类名: CoreService </br>
 * 描述: 核心服务类 </br>
 * 开发人员： souvc </br>
 * 创建时间： 2015-9-30 </br>
 * 发布版本：V1.0 </br>
 * 
 * 修正人员：王福迎
 * 修正时间：20170926
 * 增加了handler接口
 * 增加了AES认证功能
 * 修正了少数代码
 */
public class CoreService {

	/**
	 * 处理微信发来的请求
	 * 
	 * @param request
	 * @return xml
	 */
	public static String _processRequest(HttpServletRequest request) {
		// xml格式的消息数据
		String respXml = null;
		// 默认返回的文本消息内容
		String respContent = "未知的消息类型！";
		try {
			// 调用parseXml方法解析请求消息
			Map<String, String> requestMap = MessageUtil.parseXml(request);
			// 发送方帐号
			String fromUserName = requestMap.get("FromUserName");
			// 开发者微信号
			String toUserName = requestMap.get("ToUserName");
			// 消息类型
			String msgType = requestMap.get("MsgType");

			// 回复文本消息
			TextMessage textMessage = new TextMessage();
			textMessage.setToUserName(fromUserName);
			textMessage.setFromUserName(toUserName);
			textMessage.setCreateTime(new Date().getTime());
			textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);

			// 文本消息
			if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
				respContent = "您发送的是文本消息！";
			}
			// 图片消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {
				respContent = "您发送的是图片消息！";
			}
			// 语音消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {
				respContent = "您发送的是语音消息！";
			}
			// 视频消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)) {
				respContent = "您发送的是视频消息！";
			}
			// 视频消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_SHORTVIDEO)) {
				respContent = "您发送的是小视频消息！";
			}
			// 地理位置消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {
				respContent = "您发送的是地理位置消息！";
			}
			// 链接消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {
				respContent = "您发送的是链接消息！";
			}
			// 事件推送
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
				// 事件类型
				String eventType = requestMap.get("Event");
				// 关注
				if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
					respContent = "谢谢您的关注！";
				}
				// 取消关注
				else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
					// TODO 取消订阅后用户不会再收到公众账号发送的消息，因此不需要回复
				}
				// 扫描带参数二维码
				else if (eventType.equals(MessageUtil.EVENT_TYPE_SCAN)) {
					// TODO 处理扫描带参数二维码事件
				}
				// 上报地理位置
				else if (eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)) {
					// TODO 处理上报地理位置事件
				}
				// 自定义菜单
				else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
					// TODO 处理菜单点击事件
				}
			}
			// 设置文本消息的内容
			textMessage.setContent(respContent);
			// 将文本消息对象转换成xml
			respXml = MessageUtil.messageToXml(textMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return respXml;
	}

	public static String processRequest(Map<String, String> requestMap, MessageHandler messageHandler) {
		// 调用parseXml方法解析请求消息
		try {
			switch (requestMap.get("MsgType")) {
			case MessageUtil.REQ_MESSAGE_TYPE_TEXT:
				if (null != messageHandler)
					return messageHandler.onTextMessage(requestMap);
				break;
				// 图片消息
			case MessageUtil.REQ_MESSAGE_TYPE_IMAGE:
				if (null != messageHandler)
					return messageHandler.onImageMessage(requestMap);
				break;
				// 语音消息
			case MessageUtil.REQ_MESSAGE_TYPE_VOICE:
				if (null != messageHandler)
					return messageHandler.onVoiceMessage(requestMap);
				break;
				// 视频消息
			case MessageUtil.REQ_MESSAGE_TYPE_VIDEO:
				if (null != messageHandler)
					return messageHandler.onVideoMessage(requestMap);
				break;
				// 视频消息
			case MessageUtil.REQ_MESSAGE_TYPE_SHORTVIDEO:
				if (null != messageHandler)
					return messageHandler.onShortVideoMessage(requestMap);
				break;
				// 地理位置消息
			case MessageUtil.REQ_MESSAGE_TYPE_LOCATION:
				if (null != messageHandler)
					return messageHandler.onLocationMessage(requestMap);
				break;
				// 链接消息
			case MessageUtil.REQ_MESSAGE_TYPE_LINK:
				if (null != messageHandler)
					return messageHandler.onLinkMessage(requestMap);
				break;
				// 事件推送
			case MessageUtil.REQ_MESSAGE_TYPE_EVENT:
				// 事件类型
				String eventType = requestMap.get("Event");
				// 关注
				if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
					if (null != messageHandler)
						return messageHandler.onEventSubscribeMessage(requestMap);
				}
				// 取消关注
				else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
					if (null != messageHandler)
						return messageHandler.onEventUnsubscribeMessage(requestMap);
				}
				// 扫描带参数二维码
				else if (eventType.equals(MessageUtil.EVENT_TYPE_SCAN)) {
					if (null != messageHandler)
						return messageHandler.onEventScanMessage(requestMap);
				}
				// 上报地理位置
				else if (eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)) {
					if (null != messageHandler)
						return messageHandler.onEventLocationMessage(requestMap);
				}
				// 自定义菜单
				else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
					if (null != messageHandler)
						return messageHandler.onEventClickMessage(requestMap);
				}
				else if (eventType.equals(MessageUtil.EVENT_TYPE_VIEW)) {
					if (null != messageHandler)
						return messageHandler.onEventView(requestMap);
				}
				else if (eventType.equals(MessageUtil.EVENT_TYPE_TEMPLATESENDJOBFINISH)) {
					if (null != messageHandler)
						return messageHandler.onEventSendTemplateMessageDone(requestMap);
				}
				break;
			default:
				break;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("无法解析的MsgType或Event！以下是requestMap具体信息：");
		NetUtil.dumpMap(requestMap);
		return "success";
	}


}
